<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %>
<%@page import="dyyx.dto.*"%>
<%@page import="dyyx.util.*"%>
<%@page import="java.util.*"%>
<%@page import="org.apache.kafka.clients.admin.*"%>
<%@page import="org.apache.kafka.common.*"%>


<%

WebResult webResult = new WebResult();
KafkaViewWebUtil.getLogDirInfo(request, webResult);
List<KafkaTopicReplicaSummaryInfo> topicReplicaSummaryInfoList = webResult.topicReplicaSummaryInfoList;
if(topicReplicaSummaryInfoList==null){
	topicReplicaSummaryInfoList = new ArrayList<KafkaTopicReplicaSummaryInfo>();
}





%>

<%@include file="/comm.jsp"%>


<hr>
<%=new Date() %>  <br>
<%=webResult.msg %>


<hr>
brokerId: <%=webResult.brokerId %>

<hr>

<table>

<tr class='title'>

<td>topic</td>
<td>partition</td>

<td>size</td>
<td>offsetLag</td>
<td>isFuture</td>

</tr>



<%for(KafkaTopicReplicaSummaryInfo item:topicReplicaSummaryInfoList){ 

	List<KafkaReplicaInfo> replicas = item.replicas;
%>


<tr>

<td colspan="5">

<%=item.topic %>

totalSize: <%=item.totalSize %>


</td>


</tr>

<%for(KafkaReplicaInfo item2:replicas) {%>
<tr>
<td><%=item2.topic %></td>
<td><%=item2.partition %></td>
<td><%=item2.size %></td>
<td><%=item2.offsetLag %></td>
<td><%=item2.isFuture  %></td>

</tr>
<%} %>

<%} %>


</table>





<hr>


<br><br><br>
